package io.kimmking.mq.alphamq.message;

import io.kimmking.mq.alphamq.IMessage;
import lombok.Getter;
import lombok.Setter;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

public class BaseMessage<T> implements IMessage<T> {
    
    @Getter
    @Setter
    final Map<String, String> headers = new ConcurrentHashMap<>();
    
    @Getter
    @Setter
    T payload;
}
